#include "MyProcessPool.hpp"
int main()
{
    // 创建10个子进程
    MyProcessPool pp(10);
    pp.InitProcessPool([](int fd)
                       {
        while(1){
            int code = 0;
            //std::cout<<"子进程阻塞："<< getpid()<<std::endl;
            ssize_t n = read(fd,&code,sizeof(code));
            if(n> 0){
                std::cout<<"子进程被唤醒："<<getpid()<<std::endl;
                //这里可以实现具体的子进程的任务
            }
            else if(n == 0){//这里是写端关闭，就直接break就直接退出了exit(1)
                break;
            }
        } });
    // 控制子进程
    pp.ControlProcess(9);
    // 回收子进程
    pp.WaitChildProcess();
    return 0;
}